// 引进express
const express = require('express');
// 声明一个路由
const myRouter = express.Router();

// 引入数据库的文件
const db = require('../utils/database');

// 这是渲染的接口
myRouter.post('/pick_fruit_render',(req,res)=>{
    // 设置数据库
    const sql = `SELECT p_item,p_num,p_pro,p_weight,p_time FROM purchase ORDER BY p_time;`;
    db.query(sql,(err,data)=>{
        if(err){
            console.log(err);
            console.log("渲染错了");
        }else{
            // 把搜索到的数据传输回前端
            res.send(data);
        }
    })
})

// 这是查询的接口
myRouter.post("/pick_fruit_query",(req,res)=>{
    // 设置数据库
    console.log(req.body);
    let sql = `SELECT p_item,p_num,p_pro,p_weight,p_time FROM purchase WHERE p_item="${req.body.p_item}" OR p_num = "${req.body.p_num}";`
    db.query(sql,(err,data)=>{
        if (err) {
            console.log(err);
        }else{
            res.send(data);
            console.log(data);
        }
    })
})

// 新增时检查的
myRouter.post("/pick_fruit_increase",(req,res)=>{
    // 设置数据库
    // let sql = `SELECT * FROM purchase WHERE p_item = "${req.body.p_item}";`;
    let sql = `SELECT * FROM purchase WHERE p_item = "${req.body.p_item}" OR p_num = "${req.body.p_num}";`;
    let sql2 = `SELECT * FROM goods WHERE g_id = "${req.body.p_item}";`;
    let sql3 = `INSERT INTO purchase (id, p_item, p_num, p_pro, p_weight, p_time) VALUES(NULL,'${req.body.p_item}','${req.body.p_num}','${req.body.p_pro}','${req.body.p_weight}','${req.body.p_time}');`
    db.query(sql,(err,data)=>{
        if (err) {
          console.log("错了");  
        }else{
            if (data.length==0) {
                db.query(sql2,(err,data2)=>{
                    if (err) {
                        console.log("错了");
                    }else if (data2.length==0) {
                        console.log("上级没有数据");
                        res.send("上级没有数据");
                    }else{
                        console.log("准许创建");
                        res.send("准许创建,但采购单编号没有");

                        let l = req.body.p_num.length
                        if (l==16) {
                            console.log("可以创建");
                            res.send("可以创建");

                            db.query(sql3,(err,data3)=>{
                                if (err) {
                                    console.log(err);
                                }else{
                                    console.log("添加成功");
                                    res.send("添加成功");

                                    res.send(data3);
                                }
                            })

                        }else if (l<16) {
                            console.log("不够");
                            res.send("采购单编号长度不够");

                        }else{
                            console.log("超出");
                            res.send("采购单长度过长");

                        }
                    }
                })
            }else{
                console.log("已经有了这个数据");
                res.send("已经有这个数据了");

            }
        }
    })
})

// 修改
myRouter.post("/pick_fruit_change",(req,res)=>{
    // 设置数据库
    let sql = `UPDATE purchase SET p_pro = "${req.body.p_pro}",p_weight = "${req.body.p_weight}",p_time = "${req.body.p_time}" WHERE p_item = "${req.body.p_item}";`;
    db.query(sql,(err,data)=>{
        if (err) {
            console.log(err);
        }else{
            res.send(data);
        }
    })
})

// 删除
myRouter.post("/pick_fruit_del",(req,res)=>{
    // 设置数据库
    let sql = `DELETE FROM purchase WHERE p_item = "${req.body.p_item}";`;
    db.query(sql,(err,data)=>{
        if (err) {
            console.log(err);
        }else{
            res.send(data)
        }
    })
})



// 网购退还记录的接口
    // 这是渲染的接口
    myRouter.post('/online_retreat_render',(req,res)=>{
        // 设置数据库
        const sql = `SELECT 销售单号,p_id,数量,销售价,用户名称,用户手机号 FROM z_sale WHERE 状态="退货" ORDER BY z_id;`;
        db.query(sql,(err,data)=>{
            if(err){
                console.log(err);
                console.log("渲染错了");
            }else{
                // 把搜索到的数据传输回前端
                console.log(data);
                res.send(data);
            }
        })
    })

    // 这是查询的接口
    myRouter.post("/online_retreat_query",(req,res)=>{
        // 设置数据库
        console.log(req.body);
        let sql = `SELECT 销售单号,p_id,数量,销售价,用户名称,用户手机号 FROM z_sale WHERE p_id="${req.body.p_item}" ;`
        db.query(sql,(err,data)=>{
            if (err) {
                console.log(err);
            }else{
                res.send(data);
                console.log(data);
            }
        })
    })


    // 查看的接口
    myRouter.post("/online_retreat_see",(req,res)=>{
        // 设置数据库
        let sql = `SELECT * FROM z_sale WHERE 销售单号 = "${req.body.p_id}" AND 状态="退货";`
        db.query(sql,(err,data)=>{
            if (err) {
                console.log(err);
            }else{
                res.send(data);
                console.log(data);
            }
        })
    })

module.exports = myRouter;
